# -*- coding: utf-8 -*-
from airflow.operators.dummy_operator import DummyOperator
from ..tab_bagbillcode import jms_ods__tab_bagbillcode
from ..tab_barscan_arrival import jms_ods__tab_barscan_arrival
from ..tab_barscan_bagging import jms_ods__tab_barscan_bagging
from ..tab_barscan_centerarrival import jms_ods__tab_barscan_centerarrival
from ..tab_barscan_centersend import jms_ods__tab_barscan_centersend
from ..tab_barscan_collect import jms_ods__tab_barscan_collect
from ..tab_barscan_deliver import jms_ods__tab_barscan_deliver
from ..tab_barscan_difficult import jms_ods__tab_barscan_difficult
from ..tab_barscan_loading import jms_ods__tab_barscan_loading
# from ..tab_barscan_noparsepackage import jms_ods__tab_barscan_noparsepackage
# from ..tab_barscan_notallow import jms_ods__tab_barscan_notallow
from ..tab_barscan_other import jms_ods__tab_barscan_other
from ..tab_barscan_send import jms_ods__tab_barscan_send
from ..tab_barscan_sign import jms_ods__tab_barscan_sign
# from ..tab_barscan_signrep import jms_ods__tab_barscan_signrep
from ..tab_barscan_sitearrival import jms_ods__tab_barscan_sitearrival
from ..tab_barscan_sitesend import jms_ods__tab_barscan_sitesend
from ..tab_barscan_taking import jms_ods__tab_barscan_taking
from ..tab_barscan_unloading import jms_ods__tab_barscan_unloading
from ..tab_barscan_warehousing import jms_ods__tab_barscan_warehousing
# from ..tab_sitearrivalmonitor import jms_ods__tab_sitearrivalmonitor
# from ..tab_sitedelivermonitor import jms_ods__tab_sitedelivermonitor
# from ..tab_sitesendmonitor import jms_ods__tab_sitesendmonitor
from ..tab_sitetakingmonitor import jms_ods__tab_sitetakingmonitor
from ..tab_bulk_cargo_shift import jms_ods__tab_bulk_cargo_shift
# from ..tab_statistics import jms_ods__tab_statistics
from ..tab_valid_data import jms_ods__tab_valid_data
from ..tab_end_piece import jms_ods__tab_end_piece
from ..tab_platform_effect_config import jms_ods__tab_platform_effect_config
from ..tab_reback_transfer_express import jms_ods__tab_reback_transfer_express
# from ..terminal_billcode_monitor import jms_ods__terminal_billcode_monitor
from ..tab_aviation_send_record import jms_ods__tab_aviation_send_record
from ..tab_booking_space import jms_ods__tab_booking_space
from ..tab_send_goods_report import jms_ods__tab_send_goods_report
from ..tab_take_delivery import jms_ods__tab_take_delivery
#from ..tab_report_errorbagging_detail import jms_ods__tab_report_errorbagging_detail
from ..tab_agent_point import jms_ods__tab_agent_point
from ..tab_barscan_return_msg import jms_ods__tab_barscan_return_msg
from ..tab_terminal_secret import jms_ods__tab_terminal_secret
from ..tab_customer_monitor_deploy import jms_ods__tab_customer_monitor_deploy
from ..tab_customer_monitor_vips import jms_ods__tab_customer_monitor_vips
# from ..tab_stat_taking_timely_d import jms_ods__tab_stat_taking_timely_d

ods_tab_total_task_tag = DummyOperator(
    task_id='ods_tab_total_task_tag',
    email=['chenhongping@yl-scm.com','yl_bigdata@yl-scm.com'],
    retries=0,
    priority_weight=0,
)

ods_tab_total_task_tag << [
    jms_ods__tab_bagbillcode,
    jms_ods__tab_barscan_arrival,
    jms_ods__tab_barscan_bagging,
    jms_ods__tab_barscan_centerarrival,
    jms_ods__tab_barscan_centersend,
    jms_ods__tab_barscan_collect,
    jms_ods__tab_barscan_deliver,
    jms_ods__tab_barscan_difficult,
    jms_ods__tab_barscan_loading,
    # jms_ods__tab_barscan_noparsepackage,
    # jms_ods__tab_barscan_notallow,
    jms_ods__tab_barscan_other,
    jms_ods__tab_barscan_send,
    jms_ods__tab_barscan_sign,
    # jms_ods__tab_barscan_signrep,
    jms_ods__tab_barscan_sitearrival,
    jms_ods__tab_barscan_sitesend,
    jms_ods__tab_barscan_taking,
    jms_ods__tab_barscan_unloading,
    jms_ods__tab_barscan_warehousing,
    # jms_ods__tab_sitearrivalmonitor,
    # jms_ods__tab_sitedelivermonitor,
    # jms_ods__tab_sitesendmonitor,
    jms_ods__tab_sitetakingmonitor,
    jms_ods__tab_bulk_cargo_shift,
    # jms_ods__tab_statistics,
    jms_ods__tab_valid_data,
    jms_ods__tab_end_piece,
    jms_ods__tab_platform_effect_config,
    jms_ods__tab_reback_transfer_express,
    # jms_ods__terminal_billcode_monitor,
    jms_ods__tab_aviation_send_record,
    jms_ods__tab_booking_space ,
    jms_ods__tab_send_goods_report,
    jms_ods__tab_take_delivery,
    #jms_ods__tab_stat_taking_timely_d,   # 数据量太大异常，年后上线,2022-01-25改为增量拉
    #jms_ods__tab_report_errorbagging_detail,
    jms_ods__tab_agent_point,
    jms_ods__tab_barscan_return_msg,
    jms_ods__tab_terminal_secret,
    jms_ods__tab_customer_monitor_deploy,
    jms_ods__tab_customer_monitor_vips,
]


